// Copyright 2021 by 马万里. All rights reserved.
// 开发团队 ：   鸡中之霸
// 开发人员 ：   马万里
// 开发时间 ：   2021/2/26 02:12
// 文件名称 ：   test_ceph.go
// 工程名称 ：   netpan
// 开发工具 ：   GoLand
//

package main

import (
	"fmt"
	"gopkg.in/amz.v1/s3"
	"johnsonsmile.cn/netpan/store/ceph"
)

func main() {

	bucket := ceph.GetCephBucket("testbucket1")

	// 创建新的bucket
	err := bucket.PutBucket(s3.PublicRead)
	fmt.Printf("create bucket err: %v\n", err)

	// 查询这个bucket下面指定条件的object keys
	res, err := bucket.List("", "", "", 100)
	fmt.Printf("object keys: %+v\n", res)

	// 新上传一个对象
	err = bucket.Put("/testupload/a.txt", []byte("test"), "octet-stream", s3.PublicRead)
	fmt.Printf("upload err: %+v\n", err)

	// 查询这个bucket下面指定条件的object keys
	res, err = bucket.List("", "", "", 100)
	fmt.Printf("object keys: %+v\n", res)

}
